b6dc7b26a5446f1fb1d83b4f9584896dce0ee726,PayvmentDemo/src/main/java/com/payvment/continuuity/ProductFeedFlow.java,ProductProcessorFlowlet,initialize,#,89

Before Change



    @Override
    public void initialize() {
      this.productTable = new ProductTable(getFlowletContext().getDataFabric(),
          getFlowletContext());
      this.productUpdateCountTable = new CounterTable("productUpdates",
          getFlowletContext().getDataFabric(), getFlowletContext());
      this.allTimeScoreTable = new CounterTable("allTimeScores",
          getFlowletContext().getDataFabric(), getFlowletContext());
      this.topScoreTable = new SortedCounterTable("topScores",

After Change


    @Override
    public void initialize() {
      this.productTable = new ProductTable();
      getFlowletContext().getDataSetRegistry().registerDataSet(
          this.productTable);
      this.productUpdateCountTable = new CounterTable("productUpdates");
      getFlowletContext().getDataSetRegistry().registerDataSet(
          this.productUpdateCountTable);
      this.allTimeScoreTable = new CounterTable("allTimeScores");
      getFlowletContext().getDataSetRegistry().registerDataSet(
          this.allTimeScoreTable);